home *** CD-ROM | disk | FTP | other *** search
/ Openstep 4.2 (Developer) / Openstep Developer 4.2.iso / NextDeveloper / Source / GNU / uucp / uucico / protf.c < prev    next >
Encoding:
C/C++ Source or Header  |  1995-08-20  |  20.2 KB  |  849 lines
  1. /* protf.c
  2.    The 'f' protocol.
  3.  
  4.    Copyright (C) 1991, 1992, 1993 Ian Lance Taylor
  5.  
  6.    This file is part of the Taylor UUCP package.
  7.  
  8.    This program is free software; you can redistribute it and/or
  9.    modify it under the terms of the GNU General Public License as
  10.    published by the Free Software Foundation; either version 2 of the
  11.    License, or (at your option) any later version.
  12.  
  13.    This program is distributed in the hope that it will be useful, but
  14.    WITHOUT ANY WARRANTY; without even the implied warranty of
  15.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  16.    General Public License for more details.
  17.  
  18.    You should have received a copy of the GNU General Public License
  19.    along with this program; if not, write to the Free Software
  20.    Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  21.  
  22.    The author of the program may be contacted at ian@airs.com or
  23.    c/o Cygnus Support, 48 Grove Street, Somerville, MA 02144.
  24.    */
  25.  
  26. #include "uucp.h"
  27.  
  28. #if USE_RCS_ID
  29. const char protf_rcsid[] = "$Id: protf.c,v 1.33 1995/06/21 19:15:17 ian Rel $";
  30. #endif
  31.  
  32. #include <ctype.h>
  33. #include <errno.h>
  34.  
  35. #include "uudefs.h"
  36. #include "uuconf.h"
  37. #include "conn.h"
  38. #include "trans.h"
  39. #include "system.h"
  40. #include "prot.h"
  41.  
  42. /* This implementation is based on code by Piet Beertema, CWI,
  43.    Amsterdam, Sep 1984.
  44.  
  45.    This code implements the 'f' protocol, which requires a
  46.    flow-controlled error-free seven-bit data path.  It does check for
  47.    errors, but only at the end of each file transmission, so a noisy
  48.    line without error correcting modems will be unusable.
  49.  
  50.    The conversion to seven bit data is done as follows, where b
  51.    represents the character to convert:
  52.  
  53.       0 <= b <=  037: 0172, b + 0100 (0100 to 0137)
  54.     040 <= b <= 0171:       b        ( 040 to 0171)
  55.    0172 <= b <= 0177: 0173, b - 0100 ( 072 to 077)
  56.    0200 <= b <= 0237: 0174, b - 0100 (0100 to 0137)
  57.    0240 <= b <= 0371: 0175, b - 0200 ( 040 to 0171)
  58.    0372 <= b <= 0377: 0176, b - 0300 ( 072 to 077)
  59.  
  60.    This causes all output bytes to be in the range 040 to 0176; these
  61.    are the printable ASCII characters.  */
  62.  
  63. /* This structure is used to hold information when dealing with the
  64.    end of file acknowledgement.  */
  65.  
  66. struct sfinfo
  67. {
  68.   /* The functions from the generic code.  */
  69.   boolean (*psendfn) P((struct stransfer *qtrans, struct sdaemon *qdaemon));
  70.   boolean (*precfn) P((struct stransfer *qtrans, struct sdaemon *qdaemon,
  71.                const char *zdata, size_t cdata));
  72.   /* The info pointer from the generic code.  */
  73.   pointer pinfo;
  74.   /* The character to send after receiving the checksum.  */
  75.   char bsend;
  76. };
  77.  
  78. /* Internal functions.  */
  79. static boolean ffprocess_data P((struct sdaemon *qdaemon,
  80.                  boolean *pfexit, size_t *pcneed));
  81. static boolean ffawait_ack P((struct stransfer *qtrans,
  82.                   struct sdaemon *qdaemon,
  83.                   const char *zdata, size_t cdata));
  84. static boolean ffawait_cksum P((struct stransfer *qtrans,
  85.                 struct sdaemon *qdaemon,
  86.                 const char *zdata, size_t cdata));
  87. static boolean ffsend_ack P((struct stransfer *qtrans,
  88.                  struct sdaemon *qdaemon));
  89.  
  90. /* The size of the buffer we allocate to store outgoing data in.  */
  91. #define CFBUFSIZE (256)
  92.  
  93. /* The timeout to wait for data to arrive before giving up.  */
  94. static int cFtimeout = 120;
  95.  
  96. /* The maximum number of retries.  */
  97. static int cFmaxretries = 2;
  98.  
  99. /* The buffer we allocate for outgoing data.  */
  100. static char *zFbuf;
  101.  
  102. /* TRUE if we are receiving a file rather than a command.  */
  103. static boolean fFfile;
  104.  
  105. /* The checksum so far.  */
  106. static unsigned int iFcheck;
  107.  
  108. /* The last special byte (0172 to 0176) or 0 if none.  */
  109. static char bFspecial;
  110.  
  111. /* The number of times we have retried this file.  */
  112. static int cFretries;
  113.  
  114. /* Whether this file has been acknowledged.  */
  115. static boolean fFacked;
  116.  
  117. struct uuconf_cmdtab asFproto_params[] =
  118. {
  119.   { "timeout", UUCONF_CMDTABTYPE_INT, (pointer) &cFtimeout, NULL },
  120.   { "retries", UUCONF_CMDTABTYPE_INT, (pointer) &cFmaxretries, NULL },
  121.   { NULL, 0, NULL, NULL }
  122. };
  123.  
  124. /* Statistics.  */
  125.  
  126. /* The number of data bytes sent in files.  */
  127. static long cFsent_data;
  128.  
  129. /* The number of actual bytes sent in files.  */
  130. static long cFsent_bytes;
  131.  
  132. /* The number of data bytes received in files.  */
  133. static long cFrec_data;
  134.  
  135. /* The number of actual bytes received in files.  */
  136. static long cFrec_bytes;
  137.  
  138. /* The number of file retries when sending.  */
  139. static long cFsend_retries;
  140.  
  141. /* The number of file retries when receiving.  */
  142. static long cFrec_retries;
  143.  
  144. /* Start the protocol.  */
  145.  
  146. boolean
  147. ffstart (qdaemon, pzlog)
  148.      struct sdaemon *qdaemon;
  149.      char **pzlog;
  150. {
  151.   *pzlog = NULL;
  152.  
  153.   cFsent_data = 0;
  154.   cFsent_bytes = 0;
  155.   cFrec_data = 0;
  156.   cFrec_bytes = 0;
  157.   cFsend_retries = 0;
  158.   cFrec_retries = 0;
  159.  
  160.   /* Use XON/XOFF handshaking.  */
  161.   if (! fconn_set (qdaemon->qconn, PARITYSETTING_DEFAULT,
  162.            STRIPSETTING_SEVENBITS, XONXOFF_ON))
  163.     return FALSE;
  164.  
  165.   /* We sleep to allow the other side to reset the terminal; this is
  166.      what Mr. Beertema's code does.  */
  167.   usysdep_sleep (2);
  168.  
  169.   return TRUE;
  170. }
  171.  
  172. /* Shutdown the protocol.  */
  173.  
  174. /*ARGSIGNORED*/
  175. boolean
  176. ffshutdown (qdaemon)
  177.      struct sdaemon *qdaemon;
  178. {
  179.   xfree ((pointer) zFbuf);
  180.   zFbuf = NULL;
  181.   ulog (LOG_NORMAL,
  182.     "Protocol 'f': sent %ld bytes for %ld, received %ld bytes for %ld",
  183.     cFsent_bytes, cFsent_data, cFrec_bytes, cFrec_data);
  184.   if (cFsend_retries != 0 || cFrec_retries != 0)
  185.     ulog (LOG_NORMAL, "Protocol 'f' file retries: %ld sending, %ld receiving",
  186.       cFsend_retries, cFrec_retries);
  187.   cFtimeout = 120;
  188.   cFmaxretries = 2;
  189.   return TRUE;
  190. }
  191.  
  192. /* Send a command string.  We just send the string followed by a carriage
  193.    return.  */
  194.  
  195. /*ARGSUSED*/
  196. boolean
  197. ffsendcmd (qdaemon, z, ilocal, iremote)
  198.      struct sdaemon *qdaemon;
  199.      const char *z;
  200.      int ilocal;
  201.      int iremote;
  202. {
  203.   size_t clen;
  204.   char *zalc;
  205.   boolean fret;
  206.  
  207.   DEBUG_MESSAGE1 (DEBUG_UUCP_PROTO, "ffsendcmd: Sending command \"%s\"", z);
  208.  
  209.   clen = strlen (z);
  210.   zalc = zbufalc (clen + 2);
  211.   memcpy (zalc, z, clen);
  212.   zalc[clen] = '\r';
  213.   zalc[clen + 1] = '\0';
  214.   fret = fsend_data (qdaemon->qconn, zalc, clen + 1, TRUE);
  215.   ubuffree (zalc);
  216.   return fret;
  217. }
  218.  
  219. /* Get space to be filled with data.  We allocate the space from the
  220.    heap.  */
  221.  
  222. /*ARGSIGNORED*/
  223. char *
  224. zfgetspace (qdaemon, pclen)
  225.      struct sdaemon *qdaemon;
  226.      size_t *pclen;
  227. {
  228.   *pclen = CFBUFSIZE;
  229.   if (zFbuf == NULL)
  230.     zFbuf = (char *) xmalloc (CFBUFSIZE);
  231.   return zFbuf;
  232. }
  233.  
  234. /* Send out a data packet.  We have to encode the data into seven bits
  235.    and accumulate a checksum.  */
  236.  
  237. /*ARGSIGNORED*/
  238. boolean
  239. ffsenddata (qdaemon, zdata, cdata, ilocal, iremote, ipos)
  240.      struct sdaemon *qdaemon;
  241.      char *zdata;
  242.      size_t cdata;
  243.      int ilocal;
  244.      int iremote;
  245.      long ipos;
  246. {
  247.   char ab[CFBUFSIZE * 2];
  248.   char *ze;
  249.   register unsigned int itmpchk;
  250.       
  251.   cFsent_data += cdata;
  252.  
  253.   ze = ab;
  254.   itmpchk = iFcheck;
  255.   while (cdata-- > 0)
  256.     {
  257.       register int b;
  258.  
  259.       /* Rotate the checksum left.  */
  260.       if ((itmpchk & 0x8000) == 0)
  261.     itmpchk <<= 1;
  262.       else
  263.     {
  264.       itmpchk <<= 1;
  265.       ++itmpchk;
  266.     }
  267.  
  268.       /* Add the next byte into the checksum.  */
  269.       b = *zdata++ & 0xff;
  270.       itmpchk += b;
  271.  
  272.       /* Encode the byte.  */
  273.       if (b <= 0177)
  274.     {
  275.       if (b <= 037)
  276.         {
  277.           *ze++ = '\172';
  278.           *ze++ = (char) (b + 0100);
  279.         }
  280.       else if (b <= 0171)
  281.         *ze++ = (char) b;
  282.       else
  283.         {
  284.           *ze++ = '\173';
  285.           *ze++ = (char) (b - 0100);
  286.         }
  287.     }
  288.       else
  289.     {
  290.       if (b <= 0237)
  291.         {
  292.           *ze++ = '\174';
  293.           *ze++ = (char) (b - 0100);
  294.         }
  295.       else if (b <= 0371)
  296.         {
  297.           *ze++ = '\175';
  298.           *ze++ = (char) (b - 0200);
  299.         }
  300.       else
  301.         {
  302.           *ze++ = '\176';
  303.           *ze++ = (char) (b - 0300);
  304.         }
  305.     }
  306.     }
  307.  
  308.   iFcheck = itmpchk;
  309.  
  310.   cFsent_bytes += ze - ab;
  311.  
  312.   /* Passing FALSE tells fsend_data not to bother looking for incoming
  313.      information, since we really don't expect any.  */
  314.   return fsend_data (qdaemon->qconn, ab, (size_t) (ze - ab), FALSE);
  315. }
  316.  
  317. /* Process data and return the amount of data we are looking for in
  318.    *pcneed.  The 'f' protocol doesn't really reveal this, but when
  319.    transferring file we know that we need at least seven characters
  320.    for the checksum.  */
  321.  
  322. static boolean
  323. ffprocess_data (qdaemon, pfexit, pcneed)
  324.      struct sdaemon *qdaemon;
  325.      boolean *pfexit;
  326.      size_t *pcneed;
  327. {
  328.   int i;
  329.   register unsigned int itmpchk;
  330.  
  331.   *pfexit = FALSE;
  332.   if (pcneed != NULL)
  333.     *pcneed = 1;
  334.  
  335.   if (! fFfile)
  336.     {
  337.       /* A command continues until a '\r' character, which we turn
  338.      into '\0' before calling fgot_data.  */
  339.       while (iPrecstart != iPrecend)
  340.     {
  341.       for (i = iPrecstart; i < CRECBUFLEN && i != iPrecend; i++)
  342.         {
  343.           /* Some systems seem to send characters with parity, so
  344.          strip the parity bit.  */
  345.           abPrecbuf[i] &= 0x7f;
  346.  
  347.           if (abPrecbuf[i] == '\r')
  348.         {
  349.           int istart;
  350.  
  351.           DEBUG_MESSAGE1 (DEBUG_PROTO,
  352.                   "ffprocess_data: Got %d command bytes",
  353.                   i - iPrecstart + 1);
  354.  
  355.           abPrecbuf[i] = '\0';
  356.           istart = iPrecstart;
  357.           iPrecstart = (i + 1) % CRECBUFLEN;
  358.           if (pcneed != NULL)
  359.             *pcneed = 0;
  360.           return fgot_data (qdaemon, abPrecbuf + istart,
  361.                     (size_t) (i - istart + 1),
  362.                     (const char *) NULL, (size_t) 0,
  363.                     -1, -1, (long) -1, TRUE, pfexit);
  364.         }
  365.         }
  366.  
  367.       DEBUG_MESSAGE1 (DEBUG_PROTO,
  368.               "ffprocess_data: Got %d command bytes",
  369.               i - iPrecstart);
  370.  
  371.       if (! fgot_data (qdaemon, abPrecbuf + iPrecstart,
  372.                (size_t) (i - iPrecstart),
  373.                (const char *) NULL, (size_t) 0,
  374.                -1, -1, (long) -1, TRUE, pfexit))
  375.         return FALSE;
  376.  
  377.       iPrecstart = i % CRECBUFLEN;
  378.     }
  379.  
  380.       return TRUE;
  381.     }
  382.  
  383.   /* Here the data is destined for a file, and we must decode it.  */
  384.  
  385.   itmpchk = iFcheck;
  386.  
  387.   while (iPrecstart != iPrecend)
  388.     {
  389.       char *zstart, *zto, *zfrom;
  390.       int c;
  391.  
  392.       zto = zfrom = zstart = abPrecbuf + iPrecstart;
  393.  
  394.       c = iPrecend - iPrecstart;
  395.       if (c < 0)
  396.     c = CRECBUFLEN - iPrecstart;
  397.  
  398.       while (c-- != 0)
  399.     {
  400.       int b;
  401.  
  402.       /* Some systems seem to send characters with parity, so
  403.          strip the parity bit.  */
  404.       b = *zfrom++ & 0x7f;
  405.       if (b < 040 || b > 0176)
  406.         {
  407.           ulog (LOG_ERROR, "Illegal byte %d", b);
  408.           continue;
  409.         }
  410.  
  411.       /* Characters >= 0172 are always special characters.  The
  412.          only legal pair of consecutive special characters
  413.          are 0176 0176 which immediately precede the four
  414.          digit checksum.  */
  415.       if (b >= 0172)
  416.         {
  417.           if (bFspecial != 0)
  418.         {
  419.           if (bFspecial != 0176 || b != 0176)
  420.             {
  421.               ulog (LOG_ERROR, "Illegal bytes %d %d",
  422.                 bFspecial, b);
  423.               bFspecial = 0;
  424.               continue;
  425.             }
  426.  
  427.           /* Pass any initial data.  */
  428.           if (zto != zstart)
  429.             {
  430.               /* Don't count the checksum in the received bytes.  */
  431.               cFrec_bytes += zfrom - zstart - 2;
  432.               cFrec_data += zto - zstart;
  433.               if (! fgot_data (qdaemon, zstart,
  434.                        (size_t) (zto - zstart),
  435.                        (const char *) NULL, (size_t) 0,
  436.                        -1, -1, (long) -1, TRUE, pfexit))
  437.             return FALSE;
  438.             }
  439.  
  440.           /* The next characters we want to read are the
  441.              checksum, so skip the second 0176.  */
  442.           iPrecstart = (iPrecstart + zfrom - zstart) % CRECBUFLEN;
  443.  
  444.           iFcheck = itmpchk;
  445.  
  446.           /* Tell fgot_data that we've read the entire file by
  447.              passing 0 length data.  This will wind up calling
  448.              fffile to verify the checksum.  We set *pcneed to
  449.              0 because we don't want to read any more data
  450.              from the port, since we may have already read the
  451.              checksum.  */
  452.           if (pcneed != NULL)
  453.             *pcneed = 0;
  454.           return fgot_data (qdaemon, (const char *) NULL,
  455.                     (size_t) 0, (const char *) NULL,
  456.                     (size_t) 0, -1, -1, (long) -1,
  457.                     TRUE, pfexit);
  458.         }
  459.  
  460.           /* Here we have encountered a special character that
  461.          does not follow another special character.  */
  462.           bFspecial = (char) b;
  463.         }
  464.       else
  465.         {
  466.           int bnext;
  467.  
  468.           /* Here we have encountered a nonspecial character.  */
  469.  
  470.           switch (bFspecial)
  471.         {
  472.         default:
  473.           bnext = b;
  474.           break;
  475.         case 0172:
  476.           bnext = b - 0100;
  477.           break;
  478.         case 0173:
  479.         case 0174:
  480.           bnext = b + 0100;
  481.           break;
  482.         case 0175:
  483.           bnext = b + 0200;
  484.           break;
  485.         case 0176:
  486.           bnext = b + 0300;
  487.           break;
  488.         }
  489.  
  490.           *zto++ = (char) bnext;
  491.           bFspecial = 0;
  492.  
  493.           /* Rotate the checksum left.  */
  494.           if ((itmpchk & 0x8000) == 0)
  495.         itmpchk <<= 1;
  496.           else
  497.         {
  498.           itmpchk <<= 1;
  499.           ++itmpchk;
  500.         }
  501.  
  502.           /* Add the next byte into the checksum.  */
  503.           itmpchk += bnext;
  504.         }
  505.     }
  506.  
  507.       if (zto != zstart)
  508.     {
  509.       DEBUG_MESSAGE1 (DEBUG_PROTO,
  510.               "ffprocess_data: Got %d bytes",
  511.               zto - zstart);
  512.  
  513.       cFrec_data += zto - zstart;
  514.       if (! fgot_data (qdaemon, zstart, (size_t) (zto - zstart),
  515.                (const char *) NULL, (size_t) 0,
  516.                -1, -1, (long) -1, TRUE, pfexit))
  517.         return FALSE;
  518.     }
  519.  
  520.       cFrec_bytes += zfrom - zstart;
  521.  
  522.       iPrecstart = (iPrecstart + zfrom - zstart) % CRECBUFLEN;
  523.     }
  524.  
  525.   iFcheck = itmpchk;
  526.  
  527.   if (pcneed != NULL)
  528.     {
  529.       /* At this point we may have seen the first 0176 in the checksum
  530.      but not the second.  The checksum is at least seven
  531.      characters long (0176 0176 a b c d \r).  This won't help
  532.      much, but reading seven characters is a lot better than
  533.      reading two, which is what I saw in a 2400 baud log file.  */
  534.       if (bFspecial == 0176)
  535.     *pcneed = 6;
  536.       else
  537.     *pcneed = 7;
  538.     }
  539.  
  540.   return TRUE;
  541. }
  542.  
  543. /* Wait for data to come in and process it until we've finished a
  544.    command or a file.  */
  545.  
  546. boolean
  547. ffwait (qdaemon)
  548.      struct sdaemon *qdaemon;
  549. {
  550.   while (TRUE)
  551.     {
  552.       boolean fexit;
  553.       size_t cneed, crec;
  554.  
  555.       if (! ffprocess_data (qdaemon, &fexit, &cneed))
  556.     return FALSE;
  557.       if (fexit)
  558.     return TRUE;
  559.  
  560.       if (cneed > 0)
  561.     {
  562.       /* We really want to do something like get all available
  563.          characters, then sleep for half a second and get all
  564.          available characters again, and keep this up until we
  565.          don't get anything after sleeping.  */
  566.       if (! freceive_data (qdaemon->qconn, cneed, &crec, cFtimeout, TRUE))
  567.         return FALSE;
  568.       if (crec == 0)
  569.         {
  570.           ulog (LOG_ERROR, "Timed out waiting for data");
  571.           return FALSE;
  572.         }
  573.     }
  574.     }
  575. }
  576.  
  577. /* File level operations.  Reset the checksums when starting to send
  578.    or receive a file, and output the checksum when we've finished
  579.    sending a file.  */
  580.  
  581. /*ARGSUSED*/
  582. boolean
  583. fffile (qdaemon, qtrans, fstart, fsend, cbytes, pfhandled)
  584.      struct sdaemon *qdaemon;
  585.      struct stransfer *qtrans;
  586.      boolean fstart;
  587.      boolean fsend;
  588.      long cbytes;
  589.      boolean *pfhandled;
  590. {
  591.   DEBUG_MESSAGE3 (DEBUG_PROTO, "fffile: fstart %s; fsend %s; fFacked %s",
  592.           fstart ? "true" : "false", fsend ? "true" : "false",
  593.           fFacked ? "true" : "false");
  594.  
  595.   *pfhandled = FALSE;
  596.  
  597.   if (fstart)
  598.     {
  599.       iFcheck = 0xffff;
  600.       cFretries = 0;
  601.       fFacked = FALSE;
  602.       if (! fsend)
  603.     {
  604.       bFspecial = 0;
  605.       fFfile = TRUE;
  606.     }
  607.       return TRUE;
  608.     }
  609.   else
  610.     {
  611.       struct sfinfo *qinfo;
  612.  
  613.       /* We need to handle the checksum and the acknowledgement.  If
  614.      we get a successful ACK, we set fFacked to TRUE and call the
  615.      send or receive function by hand.  This will wind up calling
  616.      here again, so if fFacked is TRUE we just return out and let
  617.      the send or receive function do whatever it does.  This is a
  618.      bit of a hack.  */
  619.       if (fFacked)
  620.     {
  621.       fFacked = FALSE;
  622.       return TRUE;
  623.     }
  624.  
  625.       if (fsend)
  626.     {
  627.       char ab[sizeof "\176\176ABCD\r"];
  628.  
  629.       /* Send the final checksum.  */
  630.       sprintf (ab, "\176\176%04x\r", iFcheck & 0xffff);
  631.       if (! fsend_data (qdaemon->qconn, ab, (size_t) 7, TRUE))
  632.         return FALSE;
  633.  
  634.       /* Now wait for the acknowledgement.  */
  635.       fFfile = FALSE;
  636.       qinfo = (struct sfinfo *) xmalloc (sizeof (struct sfinfo));
  637.       qinfo->psendfn = qtrans->psendfn;
  638.       qinfo->precfn = qtrans->precfn;
  639.       qinfo->pinfo = qtrans->pinfo;
  640.       qtrans->psendfn = NULL;
  641.       qtrans->precfn = ffawait_ack;
  642.       qtrans->pinfo = (pointer) qinfo;
  643.       qtrans->fcmd = TRUE;
  644.  
  645.       *pfhandled = TRUE;
  646.  
  647.       return fqueue_receive (qdaemon, qtrans);
  648.     }
  649.       else
  650.     {
  651.       /* Wait for the checksum.  */
  652.       fFfile = FALSE;
  653.       qinfo = (struct sfinfo *) xmalloc (sizeof (struct sfinfo));
  654.       qinfo->psendfn = qtrans->psendfn;
  655.       qinfo->precfn = qtrans->precfn;
  656.       qinfo->pinfo = qtrans->pinfo;
  657.       qtrans->psendfn = NULL;
  658.       qtrans->precfn = ffawait_cksum;
  659.       qtrans->pinfo = (pointer) qinfo;
  660.       qtrans->fcmd = TRUE;
  661.  
  662.       *pfhandled = TRUE;
  663.  
  664.       return fqueue_receive (qdaemon, qtrans);
  665.     }
  666.     }
  667. }
  668.  
  669. /* Wait for the ack after sending a file and the checksum.  */
  670.  
  671. static boolean
  672. ffawait_ack (qtrans, qdaemon, zdata, cdata)
  673.      struct stransfer *qtrans;
  674.      struct sdaemon *qdaemon;
  675.      const char *zdata;
  676.      size_t cdata;
  677. {
  678.   struct sfinfo *qinfo = (struct sfinfo *) qtrans->pinfo;
  679.  
  680.   qtrans->precfn = NULL;
  681.  
  682.   /* An R means to retry sending the file.  */
  683.   if (*zdata == 'R')
  684.     {
  685.       if (! ffileisopen (qtrans->e))
  686.     {
  687.       ulog (LOG_ERROR, "Request to resent non-file");
  688.       return FALSE;
  689.     }
  690.  
  691.       ++cFretries;
  692.       if (cFretries > cFmaxretries)
  693.     {
  694.       ulog (LOG_ERROR, "Too many retries");
  695.       return FALSE;
  696.     }
  697.  
  698.       ulog (LOG_NORMAL, "Resending file");
  699.       if (! ffilerewind (qtrans->e))
  700.     {
  701.       ulog (LOG_ERROR, "rewind: %s", strerror (errno));
  702.       return FALSE;
  703.     }
  704.       qtrans->ipos = (long) 0;
  705.  
  706.       iFcheck = 0xffff;
  707.       ++cFsend_retries;
  708.  
  709.       qtrans->psendfn = qinfo->psendfn;
  710.       qtrans->precfn = qinfo->precfn;
  711.       qtrans->pinfo = qinfo->pinfo;
  712.       xfree ((pointer) qinfo);
  713.       qtrans->fsendfile = TRUE;
  714.  
  715.       return fqueue_send (qdaemon, qtrans);
  716.     }
  717.  
  718.   if (*zdata != 'G')
  719.     {
  720.       DEBUG_MESSAGE1 (DEBUG_PROTO, "fffile: Got \"%s\"", zdata);
  721.       ulog (LOG_ERROR, "File send failed");
  722.       return FALSE;
  723.     }
  724.  
  725.   qtrans->psendfn = qinfo->psendfn;
  726.   qtrans->precfn = qinfo->precfn;
  727.   qtrans->pinfo = qinfo->pinfo;
  728.   xfree ((pointer) qinfo);
  729.  
  730.   /* Now call the send function by hand after setting fFacked to TRUE.
  731.      Since fFacked is true fffile will simply return out, and the send
  732.      function can do whatever it what was going to do.  */
  733.   fFacked = TRUE;
  734.   return (*qtrans->psendfn) (qtrans, qdaemon);
  735. }
  736.  
  737. /* This function is called when the checksum arrives.  */
  738.  
  739. /*ARGSUSED*/
  740. static boolean
  741. ffawait_cksum (qtrans, qdaemon, zdata, cdata)
  742.      struct stransfer *qtrans;
  743.      struct sdaemon *qdaemon;
  744.      const char *zdata;
  745.      size_t cdata;
  746. {
  747.   struct sfinfo *qinfo = (struct sfinfo *) qtrans->pinfo;
  748.   unsigned int icheck;
  749.  
  750.   qtrans->precfn = NULL;
  751.  
  752.   if (! isxdigit (zdata[0])
  753.       || ! isxdigit (zdata[1])
  754.       || ! isxdigit (zdata[2])
  755.       || ! isxdigit (zdata[3])
  756.       || zdata[4] != '\0')
  757.     {
  758.       ulog (LOG_ERROR, "Bad checksum format");
  759.       xfree (qtrans->pinfo);
  760.       return FALSE;
  761.     }
  762.       
  763.   icheck = (unsigned int) strtol ((char *) zdata, (char **) NULL, 16);
  764.  
  765.   if (icheck != (iFcheck & 0xffff))
  766.     {
  767.       DEBUG_MESSAGE2 (DEBUG_PROTO | DEBUG_ABNORMAL,
  768.               "Checksum failed; calculated 0x%x, got 0x%x",
  769.               iFcheck & 0xffff, icheck);
  770.  
  771.       if (! ffileisopen (qtrans->e))
  772.     {
  773.       ulog (LOG_ERROR, "Failed to get non-file");
  774.       return FALSE;
  775.     }
  776.  
  777.       ++cFretries;
  778.       if (cFretries > cFmaxretries)
  779.     {
  780.       ulog (LOG_ERROR, "Too many retries");
  781.       qinfo->bsend = 'Q';
  782.     }
  783.       else
  784.     {
  785.       ulog (LOG_NORMAL, "File being resent");
  786.  
  787.       /* This bit of code relies on the receive code setting
  788.          qtrans->s.ztemp to the full name of the temporary file
  789.          being used.  */
  790.       qtrans->e = esysdep_truncate (qtrans->e, qtrans->s.ztemp);
  791.       if (! ffileisopen (qtrans->e))
  792.         return FALSE;
  793.       qtrans->ipos = (long) 0;
  794.  
  795.       iFcheck = 0xffff;
  796.       bFspecial = 0;
  797.       fFfile = TRUE;
  798.       ++cFrec_retries;
  799.  
  800.       /* Send an R to tell the other side to resend the file.  */
  801.       qinfo->bsend = 'R';
  802.     }
  803.     }
  804.   else
  805.     {
  806.       /* Send a G to tell the other side the file was received
  807.      correctly.  */
  808.       qinfo->bsend = 'G';
  809.     }
  810.  
  811.   qtrans->psendfn = ffsend_ack;
  812.  
  813.   return fqueue_send (qdaemon, qtrans);
  814. }
  815.  
  816. /* Send the acknowledgement, and then possible wait for the resent
  817.    file.  */
  818.  
  819. static boolean
  820. ffsend_ack (qtrans, qdaemon)
  821.      struct stransfer *qtrans;
  822.      struct sdaemon *qdaemon;
  823. {
  824.   struct sfinfo *qinfo = (struct sfinfo *) qtrans->pinfo;
  825.   char ab[2];
  826.  
  827.   ab[0] = qinfo->bsend;
  828.   ab[1] = '\0';
  829.   if (! ffsendcmd (qdaemon, ab, 0, 0))
  830.     return FALSE;
  831.  
  832.   qtrans->psendfn = qinfo->psendfn;
  833.   qtrans->precfn = qinfo->precfn;
  834.   qtrans->pinfo = qinfo->pinfo;
  835.   xfree ((pointer) qinfo);
  836.  
  837.   if (ab[0] == 'Q')
  838.     return FALSE;
  839.   if (ab[0] == 'R')
  840.     {
  841.       qtrans->frecfile = TRUE;
  842.       return fqueue_receive (qdaemon, qtrans);
  843.     }
  844.  
  845.   fFacked = TRUE;
  846.   return (*qtrans->precfn) (qtrans, qdaemon, (const char *) NULL,
  847.                 (size_t) 0);
  848. }
  849.